package com.sdy.mq.service;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;

public interface MqSender {
    SendResult send(Message message) throws InterruptedException, RemotingException, MQClientException, MQBrokerException;
    void send(Message message, SendCallback sendCallback) throws RemotingException, MQClientException, InterruptedException;
}
